package com.sun.kafka.service;

import org.apache.kafka.clients.consumer.ConsumerRecord;

import java.util.List;

public interface MessageService {

    void process(List<ConsumerRecord<String, String>> records);

}
